package com.redis.queue;

import com.redis.queue.pub.Pub;
import com.redis.queue.sub.Sub1Thread;
import com.redis.queue.sub.Sub2Thread;
import com.redis.utils.JedisUtils;

public class Test {
	public static void main( String[] args ){
        JedisUtils jedisUtils = new JedisUtils(10);
        Sub1Thread sub1Thread = new Sub1Thread(jedisUtils.getConnection());
        sub1Thread.start();
        Sub2Thread sub2Thread = new Sub2Thread(jedisUtils.getConnection());
        sub2Thread.start();
        Pub pub = new Pub(jedisUtils.getConnection());
        pub.start();
    }
}
